<?php

// 创建TCP服务器
$serv = new swoole_server("127.0.0.1", 9501); 

// 设置异步任务 异步进程工作数
$serv->set(array('task_worker_num' => 4));

// 投递异步任务
$serv->on("receive", function($serv, $fd, $from_id, $data) {
    $task_id = $serv->task($data); //异步ID
    echo "异步 ID: $task_id\n";
});


// 处理异步任务   异步任务处理函数  
$serv->on("task", function ($serv, $task_id, $from_id, $data) {
    echo "执行异步 ID: $task_id\n";
    $serv->finish("$data -> OK");
});

// 完成异步任务后，通知worker进程
$serv->on("finish", function ($serv, $task_id, $data) {
    echo "执行完成 Async Task[$task_id] Finish: $data\n";
});

// 启动服务
$serv->start();